// import * as mqtt from "mqtt/dist/mqtt.js"
// import { ref } from 'vue'
// const topics = ref(['/qianghonbao/push','/qiangqiang/headline'])
// const client = ref()

// export const connectMqtt = (userId) => {
// 	console.log("mqtt 开始连接...."+userId)
// 	if(!userId){
// 		console.log("mqtt userId 为空")
// 		return
// 	}
// 	const options = {
// 		clientId: "emqx_vue3_" + Math.random().toString(16).substring(2, 8),
// 		username: userId,
// 		password: 'server123',
// 		connectTimeout: 5000
// 	}
// 	console.log(options)
// 	if(client.value?.connected){
// 		console.log("mqtt 处于连接中",client.value?.connected)
// 		return
// 	}
	 
// 	let mqttClient = mqtt.connect('wx://8.138.105.21:8083/mqtt', options);
	
// 	client.value=mqttClient
	
	

// 	client.value.on('connect', function (res) {
// 		console.log("mqtt连接成功")
// 		topics.value.forEach((value) => {
// 			client.value.subscribe(value, { qos: 1 }, function (err, res) {
// 				if (!err && res.length > 0) {
// 					console.log("订阅成功:" + value)
// 				} else {
// 					console.log("订阅失败:" + value)
// 				}
		
// 			})
// 		})
// 	})
// 	client.value.on('reconnect', function () {
// 		console.log("mqtt连接重连")
// 		client.value?.end(true)
// 	})
// 	client.value.on('error', function (res) {
// 		console.log("mqtt连接错误")
// 		console.log(res)
// 	})
// 	client.value.on('close', function (res) {
// 		console.log("mqtt连接关闭")
// 		console.log(res)
// 	})
// 	client.value.on('end', function (res) {
// 		console.log("mqtt连接已断开...")
// 		console.log(res)
// 	})
// 	client.value.on('offline', function (res) {
// 		console.log("mqtt连接掉线.....")
// 		console.log(res)
// 	})
// 	client.value.on('message', function (topic, message, buffer) {
// 		console.log('接收到消息:'+message)
// 		const data = JSON.parse(message);
// 		if('/qianghonbao/push'===topic ){
// 			// #ifdef APP-PLUS
// 			uni.$emit('updateRedEnvelope',data.trendsId)
// 			// #endif
// 			//发红包消息表示这个墙墙有人发了红包
// 			//把对应墙墙的红包标识显示出来... {"code":"100","trendsId":"1854741350330200066"}
// 		}
// 		if('/qiangqiang/headline'===topic){
// 			uni.$emit('updateHeadLine',data)
// 		}

// 	})
// }


// export const disConnectMqtt = () => {
	
// 	if (client.value?.connected) {
// 		try {
// 			client.value?.end(true)
// 			client.value=null
// 			console.log("disconnected mqtt successfully")
// 		} catch (error) {
// 			console.log("disconnect mqtt error:", error)
// 		}
// 	}
// }